# -*-coding:utf-8-*-
import stomp

# 队列名
location_queue = "SYSTEM_MASTER_OUT"
conn = stomp.Connection([('192.168.120.221', 61616)])
conn.connect(username='admin', passcode='admin', wait=True)


class SampleListener(object):
    def on_message(self, headers, message):
        print('headers: %s' % headers)
        print('message: %s' % message)


def receive_from_queue():
    # 如果接受数据,就调用这个类,里面的参数是类名和类,名称必须一致
    conn.set_listener('SampleListener', SampleListener())
    # 从选择的管道中区数据,管道名,id(随便写一个数字就行)
    conn.subscribe(location_queue, 12)
    # 不能让程序停止,负责每传一次数据都得接收一次
    while True:
        pass


if __name__ == '__main__':
    receive_from_queue()
    conn.disconnect()
